package com.xzx.source;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;
import java.net.InetSocketAddress;

/**
 * 自定义RPC客户端
 *
 * @author xinzhixuan
 * @version 1.0
 * @date 2021-07-11 11:13 下午
 */
public class MyHDFSClient{
    public static void main(String[] args) throws IOException {
        RPCProtocol client = RPC.getProxy(RPCProtocol.class, RPCProtocol.versionID, new InetSocketAddress("localhost", 8888), new Configuration());
        System.out.println("客户端开始工作");
        client.mkdirs("/input");
    }


}
